package com.pk.flink.functions.source;

import org.apache.flink.api.common.functions.FilterFunction;

public class AccecssFilterFunction implements FilterFunction<String> {
    @Override
    public boolean filter(String str) throws Exception {
        String[] splits = str.split(",");
        return Double.parseDouble(splits[2]) > 100;
    }
}
